package cn.boat.router.broker.partition.strategy;

import cn.boat.router.exception.BoatMQException;

import java.util.List;

/**
 * 分区选择器
 */
public interface PartitionSelector {
    List<Integer> getPartitionDistribution(List<Integer> totalList, Integer num) throws BoatMQException, BoatMQException;
}
